package com.bujunjie.study.realtime.dim.model.vo;

import lombok.Data;

/**
 * <p>flink 捕捉 mysql binlog 的数据模型</p>
 *
 * @author bu.junjie
 * @version 1.0.0
 * @createTime 2025/9/12 16:06
 */
@Data
public class Mysql2FlinkCdcVO<T> {

    /**
     * 数据发生前的模型
     */
    private T before;

    /**
     * 数据改变后的模型
     */
    private T after;

    /**
     * 数据操作类型
     */
    private String op;

    /**
     * 数据发生的时间
     */
    private Long tsMs;
}
